//package cn.qingyun.gis.modules.init.system.message.job;
//
//import java.util.List;
//
//import cn.qingyun.gis.modules.init.system.message.entity.SysMessage;
//import cn.qingyun.gis.modules.init.system.message.service.ISysMessageService;
//import cn.vpclub.preresearch.common.util.DateUtils;
//import cn.vpclub.preresearch.modules.init.message.entity.SysMessage;
//import cn.vpclub.preresearch.modules.init.message.handle.ISendMsgHandle;
//import cn.vpclub.preresearch.modules.init.message.handle.enums.SendMsgStatusEnum;
//import cn.vpclub.preresearch.modules.init.message.handle.enums.SendMsgTypeEnum;
//import cn.vpclub.preresearch.modules.init.message.service.ISysMessageService;
//import org.quartz.Job;
//import org.quartz.JobExecutionContext;
//import org.quartz.JobExecutionException;
//import org.springframework.beans.factory.annotation.Autowired;
//
//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
//
//import lombok.extern.slf4j.Slf4j;
//
///**
// * 发送消息任务
// */
//
//@Slf4j
//public class SendMsgJob implements Job {
//
//	@Autowired
//	private ISysMessageService sysMessageService;
//
//	@Override
//	public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
//
//		log.debug(String.format(" Vpclub-Boot 发送消息任务 SendMsgJob !  时间:" + DateUtils.getTimestamp()));
//
//		// 1.读取消息中心数据，只查询未发送的和发送失败不超过次数的
//		QueryWrapper<SysMessage> queryWrapper = new QueryWrapper<SysMessage>();
//		queryWrapper.eq("es_send_status", SendMsgStatusEnum.WAIT.getCode())
//				.or(i -> i.eq("es_send_status", SendMsgStatusEnum.FAIL.getCode()).lt("es_send_num", 6));
//		List<SysMessage> sysMessages = sysMessageService.list(queryWrapper);
//		System.out.println(sysMessages);
//		// 2.根据不同的类型走不通的发送实现类
//		for (SysMessage sysMessage : sysMessages) {
//			ISendMsgHandle sendMsgHandle = null;
//			try {
//				if (sysMessage.getEsType().equals(SendMsgTypeEnum.EMAIL.getType())) {
//					sendMsgHandle = (ISendMsgHandle) Class.forName(SendMsgTypeEnum.EMAIL.getImplClass()).newInstance();
//				} else if (sysMessage.getEsType().equals(SendMsgTypeEnum.SMS.getType())) {
//					sendMsgHandle = (ISendMsgHandle) Class.forName(SendMsgTypeEnum.SMS.getImplClass()).newInstance();
//				} else if (sysMessage.getEsType().equals(SendMsgTypeEnum.WX.getType())) {
//					sendMsgHandle = (ISendMsgHandle) Class.forName(SendMsgTypeEnum.WX.getImplClass()).newInstance();
//				}
//			} catch (Exception e) {
//				log.error(e.getMessage(),e);
//			}
//			Integer sendNum = sysMessage.getEsSendNum();
//			try {
//				sendMsgHandle.sendMsg(sysMessage.getEsReceiver(), sysMessage.getEsTitle(),
//						sysMessage.getEsContent().toString());
//				// 发送消息成功
//				sysMessage.setEsSendStatus(SendMsgStatusEnum.SUCCESS.getCode());
//			} catch (Exception e) {
//				// 发送消息出现异常
//				sysMessage.setEsSendStatus(SendMsgStatusEnum.FAIL.getCode());
//			}
//			sysMessage.setEsSendNum(++sendNum);
//			// 发送结果回写到数据库
//			sysMessageService.updateById(sysMessage);
//		}
//
//	}
//
//}
